package chinaums.common.util;

import com.chinaums.ibmmq.MQMsg;
import com.chinaums.ibmmq.MQSend;

/**
 * 
 * @author liyongjie
 * @time 2017年7月19日 下午1:40:35
 * @version v1.0
 * @description MQ发送
 */
public class CfpsSendMQAppModel {
	/**
	 * 发送对象.
	 */
	private MQSend mqSend;  
	/**
	 * 队列构建器.
	 */
	private CfpsMQFactory factory;
	/**
	 * 初始化.
	 */
	public void init(){
		mqSend = new MQSend(factory.create(), null, null, false);
	}
	/**
	 * 发送到队列.
	 * @param data
	 */
	public MQMsg execute(String data){
		return mqSend.sendMsg(data, null, false, false);
	}
	public void destory(){
		if(null != mqSend){
			mqSend.getMq().disConnectMQ();
		}
	}
	public CfpsMQFactory getFactory() {
		return factory;
	}
	public void setFactory(CfpsMQFactory factory) {
		this.factory = factory;
	}
}
